package br.com.sistemasd.server;

import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
import java.util.Scanner;

public class TrataCliente implements Runnable {

	private InputStream cliente;
	private Servidor servidor;
    private Socket cli;

	public TrataCliente(InputStream cliente, Servidor servidor, Socket cli) {
		this.cliente = cliente;
		this.servidor = servidor;
		this.cli = cli;
	}

	public void run() {
        try{
			// quando chegar uma msg, distribui pra todos
			Scanner s = new Scanner(this.cliente);
			while (s.hasNextLine()) {
				servidor.distribuiMensagem(s.nextLine(), this.cli);
			}
			s.close();
		}catch(IOException ioe){
			System.out.println(ioe.getMessage());
		}
	}
}
